<?php

require __DIR__ . '/../../vendor/autoload.php';
require __DIR__ . '/../Mqtt.php';

$mqtt = new Mqtt;
$mqtt->createChannel();
$mqtt->createQueue('one2one');

$mqtt->consumeMsg(function($msg) {
    echo $msg . PHP_EOL;
});